package org.witsoft.localmq;

import org.witsoft.localmq.model.Message;

import java.util.List;

/**
 * @ClassName: MqMessageBroker
 * @Description:
 * @Author: Colin
 * @Date: 2020/12/26 6:24 PM
 * @Version 1.0
 **/
public interface MessageBroker {

    void produce(List<Message> messages);

    int getQueueSize();

    long getQueueDataSize();

}
